package com.rc.saas.mini.config;

import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.annotation.EnableKafka;

/**
 * kafka配置，实际上，在KafkaAutoConfiguration中已经有默认的根据配置文件信息创建配置
 * Created by Sven on 2021/02/09
 */
@Configuration
@EnableKafka
public class KafkaConfig {
//    @Bean
//    public NewTopic initialTopic() {
//        return new NewTopic("testtopic",8, (short) 2 );
//    }
//​
//    // 如果要修改分区数，只需修改配置值重启项目即可
//    // 修改分区数并不会导致数据的丢失，但是分区数只能增大不能减小
//    @Bean
//    public NewTopic updateTopic() {
//        return new NewTopic("testtopic",10, (short) 2 );
//    }
}
